package com.boarsoft.boar.batch.demo.flow.bigfile;

import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.boarsoft.flow.core.bean.JoinHandler;

/**
 * @ClassName: LoadDpfm02Join
 * @Description: 分线程装载完成后处理
 */
public class LoadDpfm02Join implements JoinHandler {
	private static final Logger log = LoggerFactory.getLogger(LoadDpfm02Join.class);

	@Override
	public Object join(Object flowData, Map<String, Object> resultMap) {
		log.info("加载dpfm02共耗时：{}ms", System.currentTimeMillis() - LoadDpfm02Fork.loadDpfm02ForkStart);
		return resultMap;
	}
}
